package com.hr.reactive.flux;


import com.hr.reactive.common.Utils;

/**
 * @author huran
 */
public class Lec08NonBlockingStreamMessages {
    public static void main(String[] args) {
        var client = new ExternalServiceClient();
        client.getData().subscribe(Utils.subscriber());
        Utils.sleepSeconds(3000);
    }
}
